2f3c5b85bcf0a4ac474c1350dc0a74e88bd77e87,clustered/server/src/main/java/org/ehcache/clustered/server/store/ClusterTierActiveEntity.java,ClusterTierActiveEntity,clearClientTrackedAtReconnectComplete,#,568

Before Change


  private void clearClientTrackedAtReconnectComplete() {
    if (!reconnectComplete.get()) {
      if (reconnectComplete.compareAndSet(false, true)) {
        stateService.getClientMessageTracker(storeIdentifier).reconcileTrackedClients(getTrackedClients().collect(toSet()));
      }
    }
  }

After Change


  private void clearClientTrackedAtReconnectComplete() {
    if (!reconnectComplete.get()) {
      if (reconnectComplete.compareAndSet(false, true)) {
        ClientMessageTracker clientMessageTracker = stateService.getClientMessageTracker(storeIdentifier);
        if (clientMessageTracker != null) {
          clientMessageTracker.reconcileTrackedClients(getTrackedClients().collect(toSet()));
        }
      }